#ifndef __APP_MQTT_H__
#define __APP_MQTT_H__


int app_mqtt_init(void);

void app_mqtt_close(void);

//mqtt发送数据（字符串）给mqtt服务器（同步发送）
//参数1：指针
//参数2：字符串长度
int app_mqtt_send(char *payload, int payload_len);

//处理回调函数的函数，收mqtt服务器的数据
void app_mqtt_regiaterReceiveCallback(int (*calllback)(char *payload, int payload_len));


#endif